package com.yeming.flink.practice

import org.apache.flink.streaming.api.scala._

object StreamDemo {

  def main(args: Array[String]): Unit = {
    //初始化环境变量
    val streamEnv: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    //修改并行度
    streamEnv.setParallelism(1)
    //设置数据源,读取HDFS文件
    //Transformation
    //Sink
    streamEnv.execute("")
  }
}
